package test.enba.mq.consumer.kafka;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class KafkaConsumerService {

    /*
  Kafka中没有传统意义上的队列概念，但通过设置消费者组可以模拟出类似点对点的效果
  在 Kafka 中，点对点模式可以通过为消费者指定唯一的消费者组来实现。同一消费者组内的消费者实例会竞争消费主题中的消息，即每条消息只会被组内的一个消费者消费。
   * */

  @KafkaListener(topics = "test_topic", groupId = "group-1")
  public void listen(String message) {
    System.out.println("consumer1 Received message in group 'group-1': " + message);
  }
}
